package single_ws_mon

import (
	"fmt"
	"hft/global"
	"time"

	"go.mongodb.org/mongo-driver/mongo"
)

// 消息存储
type Message struct {
	Sender     string   `bson:"sender"`      //发送者
	Recipient  string   `bson:"recipient"`   //接受者
	Type       string   `bson:"type"`        //消息类型
	MetaData   MetaData `bson:"meta_data"`   //扩展数据
	CreateTime int      `bson:"create_time"` //创建时间
}

type MetaData struct {
	MediaID string `bson:"media_id"` //媒体id
	LouPan  int    `bson:"lou_pan"`  //楼盘id
}

// 库名称
const Database = "single_chat"

// 集合名称
func Collection(ClientID string, SendID string, pageName string) string {
	return fmt.Sprintf("%v-%v-%v-%v", ClientID, SendID, pageName, time.Now().Format("200601")) //存储一个月
}

// 选择库
func CB() *mongo.Database {
	return global.OC_MON.Database(Database)
}

// 选择集合
func CC(ClientID string, SendID string, pageName string) *mongo.Collection {
	return CB().Collection(Collection(ClientID, SendID, pageName))
}
